package com.cellulam.framework.mq.listener;

import com.cellulam.framework.mq.RocketMqConsumerConfig;

public interface MqListener {
    void start();

    void initConsumer(RocketMqConsumerConfig consumerConfig);

    void subscribe(String groupId, String topic, String subExpression);
}
